package com.yiwyn.sink;

import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;

public class CustomSink extends RichSinkFunction<String> {
    private static final long serialVersionUID = -836571213864491404L;


    @Override
    public void invoke(String value, Context context) throws Exception {

        System.out.println("value:" + value);

    }
}
